package com.talent.service.iot.mqtt.service;

import com.talent.service.iot.mqtt.model.request.TlMqttPublishReq;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * @ClassName：IMqttRetainMsgService
 * @Author: hszhou
 * @Date: 2025/1/8 14:00
 * @Description: 必须描述类做什么事情, 实现什么功能
 */
public interface IMqttRetainMsgService {

    /**
     * 通过主题获取到该主题的保留消息
     * @param topic
     * @return
     */
    Mono<TlMqttPublishReq> save(String topic, TlMqttPublishReq req);

    Flux<TlMqttPublishReq> find(String topic);

    void clear(String topic);


}
